Interface Partitioner

    • Method Detail

      • getPartitionPath

        String getPartitionPath​(Tuple tuple)
        Return a relative path that the tuple should be written to. For example, if an HdfsBolt were configured to write to /common/output and a partitioner returned "/foo" then the bolt should open a file in "/common/output/foo"

        A best practice is to use Path.SEPARATOR instead of a literal "/"

        Parameters:
        tuple - The tuple for which the relative path is being calculated.