Interface TrackingStreamingCallback<K,​V>

    • Method Detail

      • onRecordDeserialized

        void onRecordDeserialized()
        This will be invoked when any record deserialization happens.
      • onDeserializationCompletion

        void onDeserializationCompletion​(java.util.Optional<java.lang.Exception> exception,
                                         int successKeyCount,
                                         int duplicateEntryCount)
        This will be invoked when Venice Client deserialization is done.
        Parameters:
        exception -
        successKeyCount - , this param indicates the total number of existing keys
        duplicateEntryCount -