...
For instance, the records being processed may encode an event time of that record, which needs to be one of the partition keys.
Jira Legacy | ||||||
---|---|---|---|---|---|---|
|
API
...
User will need to extend and implement a DynamicPartitioner, which is responsible for defining the PartitionKey to use for each record.
For each of the partition keys that this DynamicPartitioner returns, a partition will be created in the output PartitionedFileSet dataset.
...