class StreamTask extends AbstractInvokable implements AsyncExceptionHandler {

	public String getName() {
		return getEnvironment().getTaskInfo().getTaskNameWithSubtasks();
	}

	protected  StreamTask(Environment env);
	protected  StreamTask(Environment env, @Nullable ProcessingTimeService timeProvider);
	protected  StreamTask(
			Environment environment,
			@Nullable ProcessingTimeService timeProvider,
			Thread.UncaughtExceptionHandler uncaughtExceptionHandler);

}