Sign in
apache
/
nifi-minifi-cpp
/
refs/heads/apache-processor-c-api
/
.
/
docker
/
test
/
integration
/
minifi
/
processors
tree: 3d8877f7e870115a097bb2a8cbe5ce891effab89 [
path history
]
[
tgz
]
__init__.py
AddPythonAttribute.py
AzureBlobStorageProcessorBase.py
ChunkDocument.py
CollectKubernetesPodMetrics.py
ConsumeKafka.py
ConsumeMQTT.py
ConvertRecord.py
CountingProcessor.py
CreateFlowFile.py
CreateNothing.py
DefragmentText.py
DeleteAzureBlobStorage.py
DeleteGCSObject.py
DeleteS3Object.py
EvaluateExpressionLanguageChecker.py
EvaluateJsonPath.py
ExecuteScript.py
ExecuteSQL.py
ExpressionLanguagePropertyWithValidator.py
FailureWithAttributes.py
FailureWithContent.py
FetchAzureBlobStorage.py
FetchFile.py
FetchGCSObject.py
FetchModbusTcp.py
FetchOPCProcessor.py
FetchS3Object.py
GaussianDistributionWithNumpy.py
GenerateFlowFile.py
GetCouchbaseKey.py
GetFile.py
HashContent.py
InvokeHTTP.py
ListAzureBlobStorage.py
ListenHTTP.py
ListenSyslog.py
ListenTCP.py
ListFile.py
ListGCSBucket.py
ListS3.py
LogAttribute.py
LogDynamicProperties.py
LogOnDestructionProcessor.py
MoveContentToJson.py
NifiStyleLogDynamicProperties.py
ParseDocument.py
PostElasticsearch.py
ProcessContextInterfaceChecker.py
PublishKafka.py
PublishMQTT.py
PushGrafanaLokiGrpc.py
PushGrafanaLokiREST.py
PutAzureBlobStorage.py
PutCouchbaseKey.py
PutFile.py
PutGCSObject.py
PutKinesisStream.py
PutOPCProcessor.py
PutS3Object.py
PutSplunkHTTP.py
PutSQL.py
QueryDatabaseTable.py
QuerySplunkIndexingStatus.py
RelativeImporterProcessor.py
RemoveFlowFile.py
ReplaceText.py
RotatingForwarder.py
RouteOnAttribute.py
RouteText.py
RunLlamaCppInference.py
SetRecordField.py
SpecialPropertyTypeChecker.py
SplitJson.py
SplitText.py
TailFile.py
TestStateManager.py
TransferToOriginal.py
UpdateAttribute.py