You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
There are two methods, encodePartition and generatePartitionedPath. generatePartitionedPath takes the result of encodedPartition() and does some extra decoration on it. generatePartitionedPath is tested but the meat of the partitioner class(encodePartition) is not. Any idea why? The only thing I can see is that it deals with time and unit testing based on time when timezones and milliseconds are involved can be tricky.
There are two methods,
encodePartition
andgeneratePartitionedPath
.generatePartitionedPath
takes the result of encodedPartition() and does some extra decoration on it.generatePartitionedPath
is tested but the meat of the partitioner class(encodePartition
) is not. Any idea why? The only thing I can see is that it deals with time and unit testing based on time when timezones and milliseconds are involved can be tricky.example:
kafka-connect-hdfs/src/test/java/io/confluent/connect/hdfs/partitioner/DailyPartitionerTest.java
Line 45 in 092f38d
The text was updated successfully, but these errors were encountered: