@Test public void testGetPathFormat() { BiHourlyPartitioner partitioner = (BiHourlyPartitioner) configurePartitioner( new BiHourlyPartitioner(), null, null); assertThat(partitioner.getPathFormat(), is(PATH_FORMAT)); }
public String getPathFormat() { return pathFormat; }
TimeBasedPartitioner extends DefaultPartitioner<T> { public String getPathFormat() { return pathFormat; } }
TimeBasedPartitioner extends DefaultPartitioner<T> { public String getPathFormat() { return pathFormat; }  }
TimeBasedPartitioner extends DefaultPartitioner<T> { public String getPathFormat() { return pathFormat; }  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 String getPathFormat() { return pathFormat; }  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);  }