@Test public void testNumericRecordFieldTimeMap() { String timeField = "timestamp"; TimeBasedPartitioner<String> partitioner = configurePartitioner( new TimeBasedPartitioner<>(), timeField, null); assertThat(partitioner.getTimestampExtractor(), instanceOf( TimeBasedPartitioner.RecordFieldTimestampExtractor.class)); Number ts = Integer.MAX_VALUE; testMapNumericTimestampPartitionEncoding( partitioner, timeField, ts, Schema.INT32_SCHEMA, new DateTime(ts.intValue())); ts = DATE_TIME.getMillis(); testMapNumericTimestampPartitionEncoding( partitioner, timeField, ts, Schema.INT64_SCHEMA, DATE_TIME); }
public TimestampExtractor getTimestampExtractor() { return timestampExtractor; }
TimeBasedPartitioner extends DefaultPartitioner<T> { public TimestampExtractor getTimestampExtractor() { return timestampExtractor; } }
TimeBasedPartitioner extends DefaultPartitioner<T> { public TimestampExtractor getTimestampExtractor() { return timestampExtractor; }  }
TimeBasedPartitioner extends DefaultPartitioner<T> { public TimestampExtractor getTimestampExtractor() { return timestampExtractor; }  static long getPartition(long timeGranularityMs, long timestamp, DateTimeZone timeZone); long getPartitionDurationMs(); String getPathFormat(); TimestampExtractor getTimestampExtractor(); @Override void configure(Map<String, Object> config); @Override String encodePartition(SinkRecord sinkRecord, long nowInMillis); @Override String encodePartition(SinkRecord sinkRecord); @Override List<T> partitionFields(); TimestampExtractor newTimestampExtractor(String extractorClassName); }
TimeBasedPartitioner extends DefaultPartitioner<T> { public TimestampExtractor getTimestampExtractor() { return timestampExtractor; }  static long getPartition(long timeGranularityMs, long timestamp, DateTimeZone timeZone); long getPartitionDurationMs(); String getPathFormat(); TimestampExtractor getTimestampExtractor(); @Override void configure(Map<String, Object> config); @Override String encodePartition(SinkRecord sinkRecord, long nowInMillis); @Override String encodePartition(SinkRecord sinkRecord); @Override List<T> partitionFields(); TimestampExtractor newTimestampExtractor(String extractorClassName);  }