@Test public void testGetDurationMs() { BiHourlyPartitioner partitioner = (BiHourlyPartitioner) configurePartitioner( new BiHourlyPartitioner(), null, null); assertThat(partitioner.getPartitionDurationMs(), is(BiHourlyPartitioner.partitionDurationMs)); }
public long getPartitionDurationMs() { return partitionDurationMs; }
TimeBasedPartitioner extends DefaultPartitioner<T> { public long getPartitionDurationMs() { return partitionDurationMs; } }
TimeBasedPartitioner extends DefaultPartitioner<T> { public long getPartitionDurationMs() { return partitionDurationMs; }  }
TimeBasedPartitioner extends DefaultPartitioner<T> { public long getPartitionDurationMs() { return partitionDurationMs; }  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 long getPartitionDurationMs() { return partitionDurationMs; }  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);  }