Skip to content

Commit

Permalink
Merge pull request #55 from kestra-io/fix/bulk-insert
Browse files Browse the repository at this point in the history
Update Bulk.java
  • Loading branch information
anna-geller authored Jan 10, 2024
2 parents c701b42 + 143fd1e commit 9ac891d
Showing 1 changed file with 10 additions and 12 deletions.
22 changes: 10 additions & 12 deletions src/main/java/io/kestra/plugin/azure/storage/table/Bulk.java
Original file line number Diff line number Diff line change
Expand Up @@ -38,32 +38,30 @@
"connectionString: \"DefaultEndpointsProtocol=...==\"",
"table: \"mydata\"",
"from:",
" partitionKey: \"color\"",
" rowKey: \"green\"",
" type: \"UPSERT_MERGE\"",
" properties:",
" \"code\": \"00FF00\"",
" - partitionKey: \"color\"",
" rowKey: \"green\"",
" type: \"UPSERT_MERGE\"",
" properties:",
" \"code\": \"00FF00\""
}
)
}
)
@Schema(
title = "Inserts or update an entities into the table."
title = "Inserts or updates entities into the table. Make sure to pass either a list of entities or a file with a list of entities."
)
public class Bulk extends AbstractTableStorage implements RunnableTask<Bulk.Output> {
@Schema(
title = "Source of message send",
description = "Can be an internal storage uri, a map or a list." +
"with the following format: partitionKey, rowKey, type, properties"
title = "Source of a message",
description = "Can be an internal storage URI or a list of maps " +
"in the format `partitionKey`, `rowKey`, `type`, `properties`, as shown in the example."
)
@NotNull
@PluginProperty(dynamic = true)
private Object from;

@Schema(
title = "The default operation type to be applied to the entity.",
description = "Can be an internal storage uri, a map or a list." +
"with the following format: partitionKey, rowKey, properties"
title = "The default operation type to be applied to the entity."
)
@NotNull
@PluginProperty(dynamic = true)
Expand Down

0 comments on commit 9ac891d

Please sign in to comment.