public class PipesConfigBase extends ConfigBase
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_MAX_FILES_PROCESSED_PER_PROCESS |
static long |
DEFAULT_MAX_FOR_EMIT_BATCH
default size to send back to the PipesClient for batch
emitting.
|
static int |
DEFAULT_NUM_CLIENTS |
static long |
DEFAULT_SHUTDOWN_CLIENT_AFTER_MILLS |
static long |
DEFAULT_STARTUP_TIMEOUT_MILLIS |
static long |
DEFAULT_TIMEOUT_MILLIS |
Constructor and Description |
---|
PipesConfigBase() |
Modifier and Type | Method and Description |
---|---|
List<String> |
getForkedJvmArgs() |
String |
getJavaPath() |
int |
getMaxFilesProcessedPerProcess()
Restart the forked PipesServer after it has processed this many files to avoid
slow-building memory leaks.
|
long |
getMaxForEmitBatchBytes()
What is the maximum bytes size per extract that
will be allowed to be shipped back to the emit queue in the forking process.
|
int |
getNumClients() |
long |
getShutdownClientAfterMillis() |
long |
getSleepOnStartupTimeoutMillis() |
long |
getStartupTimeoutMillis() |
Path |
getTikaConfig() |
long |
getTimeoutMillis() |
void |
setForkedJvmArgs(List<String> jvmArgs) |
void |
setJavaPath(String javaPath) |
void |
setMaxFilesProcessedPerProcess(int maxFilesProcessedPerProcess) |
void |
setMaxForEmitBatchBytes(long maxForEmitBatchBytes) |
void |
setNumClients(int numClients) |
void |
setShutdownClientAfterMillis(long shutdownClientAfterMillis)
If the client has been inactive after this many milliseconds,
shut it down.
|
void |
setSleepOnStartupTimeoutMillis(long sleepOnStartupTimeoutMillis) |
void |
setStartupTimeoutMillis(long startupTimeoutMillis) |
void |
setTikaConfig(Path tikaConfig) |
void |
setTikaConfig(String tikaConfig) |
void |
setTimeoutMillis(long timeoutMillis)
How long to wait in milliseconds before timing out the forked process.
|
buildComposite, buildComposite, buildSingle, buildSingle, configure, handleSettings
public static final long DEFAULT_MAX_FOR_EMIT_BATCH
public static final long DEFAULT_TIMEOUT_MILLIS
public static final long DEFAULT_STARTUP_TIMEOUT_MILLIS
public static final long DEFAULT_SHUTDOWN_CLIENT_AFTER_MILLS
public static final int DEFAULT_NUM_CLIENTS
public static final int DEFAULT_MAX_FILES_PROCESSED_PER_PROCESS
public long getTimeoutMillis()
public void setTimeoutMillis(long timeoutMillis)
timeoutMillis
- public long getShutdownClientAfterMillis()
public void setShutdownClientAfterMillis(long shutdownClientAfterMillis)
shutdownClientAfterMillis
- public int getNumClients()
public void setNumClients(int numClients)
public void setStartupTimeoutMillis(long startupTimeoutMillis)
public int getMaxFilesProcessedPerProcess()
public void setMaxFilesProcessedPerProcess(int maxFilesProcessedPerProcess)
public Path getTikaConfig()
public void setTikaConfig(Path tikaConfig)
public void setTikaConfig(String tikaConfig)
public String getJavaPath()
public void setJavaPath(String javaPath)
public long getStartupTimeoutMillis()
public long getMaxForEmitBatchBytes()
0
, this will never send an extract back for batch emitting,
but will always emit the extract directly from the forked PipeServer.
If set to -1
, this will always send the extract back for batch emitting.public void setMaxForEmitBatchBytes(long maxForEmitBatchBytes)
public long getSleepOnStartupTimeoutMillis()
public void setSleepOnStartupTimeoutMillis(long sleepOnStartupTimeoutMillis)
Copyright © 2007–2021 The Apache Software Foundation. All rights reserved.