Class ParentHelixOfflinePushAccessor


  • public class ParentHelixOfflinePushAccessor
    extends java.lang.Object
    • Field Detail

      • OFFLINE_PUSH_SUB_PATH

        public static final java.lang.String OFFLINE_PUSH_SUB_PATH
        See Also:
        Constant Field Values
    • Constructor Detail

      • ParentHelixOfflinePushAccessor

        public ParentHelixOfflinePushAccessor​(org.apache.helix.zookeeper.impl.client.ZkClient zkClient,
                                              HelixAdapterSerializer adapter)
    • Method Detail

      • getOfflinePushStatus

        public OfflinePushStatus getOfflinePushStatus​(java.lang.String clusterName,
                                                      java.lang.String kafkaTopic)
      • getAllPushNames

        public java.util.List<java.lang.String> getAllPushNames​(java.lang.String clusterName)