@Test public void testRemovePathFormatEndDelim() { Map<String, Object> config = new HashMap<>(); config.put(PartitionerConfig.PATH_FORMAT_CONFIG, "'year='YYYY/"); TimeBasedPartitioner<String> partitioner = configurePartitioner( new TimeBasedPartitioner<>(), null, config); assertThat(partitioner.getPathFormat(), is("'year='YYYY")); }
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);  }