Interface PartitionFetcher.Context<P>

    • Method Detail

      • open

        void open()
           throws Exception
        open the resources of the Context, this method should first call before call other methods.
        Throws:
        Exception
      • getComparablePartitionValueList

        List<PartitionFetcher.Context.ComparablePartitionValue> getComparablePartitionValueList()
                                                                                         throws Exception
        Get list that contains partition with comparable object.

        For 'create-time' and 'partition-time',the comparable object type is Long which represents time in milliseconds, for 'partition-name', the comparable object type is String which represents the partition names string.

        Throws:
        Exception
      • close

        void close()
            throws Exception
        close the resources of the Context, this method should call when the context do not need any more.
        Throws:
        Exception