public class SuspendableOutputStream extends FilterOutputStream implements JobStatus
| Modifier and Type | Class and Description |
|---|---|
static class |
SuspendableOutputStream.StreamStoppedException |
JobStatus.StateoutSTREAM_PATH_SUFFIX| Constructor and Description |
|---|
SuspendableOutputStream(OutputStream os) |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
JobStatus.State[] |
getAllowedHumanStateChanges()
Indicate which state changes a human user can currently request,
based on our state.
|
Date |
getCreationTime()
Not implemented
|
String |
getPath()
Not implemented
|
JobProgressInfo |
getProgressInfo()
Not implemented
|
JobStatus.State |
getState()
Return the job's current state
|
String |
getStreamPath()
Not implemented
|
void |
requestStateChange(JobStatus.State s)
Only SUSPENDED, STOP, and RUNNING make sense here
|
void |
write(byte[] b) |
void |
write(byte[] b,
int off,
int len) |
void |
write(int b) |
flushpublic SuspendableOutputStream(OutputStream os)
public void write(byte[] b,
int off,
int len)
throws IOException
write in class FilterOutputStreamIOExceptionpublic void write(byte[] b)
throws IOException
write in class FilterOutputStreamIOExceptionpublic void write(int b)
throws IOException
write in class FilterOutputStreamIOExceptionpublic void close()
throws IOException
close in interface Closeableclose in interface AutoCloseableclose in class FilterOutputStreamIOExceptionpublic JobStatus.State getState()
JobStatuspublic void requestStateChange(JobStatus.State s)
requestStateChange in interface JobStatuspublic JobStatus.State[] getAllowedHumanStateChanges()
JobStatusgetAllowedHumanStateChanges in interface JobStatuspublic String getPath()
getPath in interface JobStatusUnsupportedOperationExceptionpublic String getStreamPath()
getStreamPath in interface JobStatusUnsupportedOperationExceptionpublic Date getCreationTime()
getCreationTime in interface JobStatusUnsupportedOperationExceptionpublic JobProgressInfo getProgressInfo()
getProgressInfo in interface JobStatusUnsupportedOperationExceptionCopyright © 2007–2016 The Apache Software Foundation. All rights reserved.