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 Summary
All Methods Static Methods Instance Methods Abstract Methods Deprecated Methods Modifier and Type Method Description static InstanceStreamService
getInstance(Session session)
Deprecated.The method provides the default implementation of the instance stream service.void
recreateStreams(Identifier instanceName)
Deprecated.The method recreates task reactor instance streams to extend their staleness time.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.
-
-
-
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.
-
-