Interface InstanceStreamService


  • @Deprecated
    public interface InstanceStreamService
    Deprecated.
    This class is a temporary solution for the problem with Snowflake Streams staleness. It will be most probably deleted in the future versions of the SDK - be aware of it when using it.
    • Method Detail

      • recreateStreams

        void recreateStreams​(Identifier instanceName)
        Deprecated.
        The method recreates task reactor instance streams to extend their staleness time.
        Parameters:
        instanceName - tha name of the Task Reactor instance.
      • recreateStreamsIfRequired

        void recreateStreamsIfRequired​(Identifier instanceName)
        Deprecated.
        The method recreate task reactor instance streams to extend their staleness time only when the appropriate time passed since the last recreation.
        Parameters:
        instanceName - the name of the Task Reactor instance.
      • getInstance

        static InstanceStreamService getInstance​(Session session)
        Deprecated.
        The method provides the default implementation of the instance stream service.
        Parameters:
        session - Snowpark session.
        Returns:
        default instance stream service instance.