MCPcopy Create free account

hub / github.com/apache/nifi-minifi-cpp / functions

Functions5,249 in github.com/apache/nifi-minifi-cpp

↓ 2 callersMethodmodifyAttributes
libminifi/src/provenance/Provenance.cpp:424
↓ 2 callersMethodmultiPut
libminifi/src/Connection.cpp:158
↓ 2 callersFunctionnegotiateCodec
nanofi/src/sitetosite/CRawSocketProtocol.c:993
↓ 2 callersMethodnotifyWork
libminifi/src/core/Connectable.cpp:138
↓ 2 callersMethodoffer
extensions/libarchive/BinFiles.cpp:212
↓ 2 callersMethodonEnable
extensions/coap/controllerservice/CoapConnector.cpp:63
↓ 2 callersMethodonSchedule
nanofi/src/cxx/CallbackProcessor.cpp:36
↓ 2 callersMethodonTrigger
nanofi/src/cxx/CallbackProcessor.cpp:42
↓ 2 callersMethodonTrigger
libminifi/test/KamikazeProcessor.cpp:69
↓ 2 callersFunctionopenFile
extensions/standard-processors/processors/TailFile.cpp:175
↓ 2 callersFunctionparseEncrypted
libminifi/src/utils/EncryptionUtils.cpp:115
↓ 2 callersMethodparsePortYaml
libminifi/src/core/yaml/YamlConfiguration.cpp:707
↓ 2 callersFunctionparse_basic_cmdline_args
libminifi/test/integration/IntegrationBase.h:173
↓ 2 callersMethodpersistProperties
libminifi/src/properties/Properties.cpp:94
↓ 2 callersMethodpickIncomingConnection
libminifi/src/core/Processor.cpp:384
↓ 2 callersMethodprepareStatement
extensions/sql/services/ODBCConnector.h:64
↓ 2 callersMethodprocess
libminifi/test/archive-tests/MergeFileTests.cpp:100
↓ 2 callersMethodprocess
extensions/sql/data/SQLRowsetProcessor.cpp:35
↓ 2 callersMethodprocess
extensions/http-curl/tests/unit/InvokeHTTPTests.cpp:154
↓ 2 callersFunctionpull_trace
libminifi/src/utils/BackTrace.cpp:58
↓ 2 callersMethodput_file_contents
(self, contents, file_abs_path)
docker/test/integration/minifi/core/DockerTestCluster.py:217
↓ 2 callersFunctionrandomBytes
libminifi/src/utils/EncryptionUtils.cpp:48
↓ 2 callersMethodread
libminifi/src/utils/file/FileSystem.cpp:41
↓ 2 callersMethodread
libminifi/include/sitetosite/Peer.h:300
↓ 2 callersMethodread
extensions/http-curl/client/HTTPStream.cpp:84
↓ 2 callersMethodread
I don't like surrounding this with a Buffered Input Stream, but it seems that certain features expect this Case in point, CSV Reader: createRecordRe
extensions/jni/nifi-framework-jni/src/main/java/org/apache/nifi/processor/JniProcessSession.java:182
↓ 2 callersMethodreadFlowFile
(FlowFile source)
extensions/jni/nifi-framework-jni/src/main/java/org/apache/nifi/processor/JniProcessSession.java:237
↓ 2 callersFunctionread_uint32_t
nanofi/src/core/cstream.c:132
↓ 2 callersFunctionreadline
readline - read a '\n' terminated line from socket fd into buffer bufptr of size len. The line in the buffer is terminated with '\0'. It returns -
libminifi/test/Server.cpp:197
↓ 2 callersMethodreconnect
extensions/mqtt/controllerservice/MQTTControllerService.h:266
↓ 2 callersMethodreconnect
extensions/mqtt/processors/AbstractMQTTProcessor.cpp:155
↓ 2 callersMethodregisterClass
* Register a class with the give ProcessorFactory */
libminifi/include/core/ClassLoader.h:304
↓ 2 callersMethodreleaseCoreResources
extensions/script/python/PythonProcessor.cpp:58
↓ 2 callersMethodreleaseFlowFile
extensions/script/ScriptFlowFile.cpp:83
↓ 2 callersMethodremove
extensions/jni/jvm/JniReferenceObjects.cpp:27
↓ 2 callersMethodremoveAttribute
libminifi/src/core/FlowFile.cpp:164
↓ 2 callersMethodremoveAttribute
(FlowFile flowFile, String key)
extensions/jni/nifi-framework-jni/src/main/java/org/apache/nifi/processor/JniProcessSession.java:111
↓ 2 callersMethodremoveChildUuid
Remove Child UUID
libminifi/include/provenance/Provenance.h:302
↓ 2 callersFunctionremove_directory
nanofi/src/core/file_utils.c:63
↓ 2 callersMethodrename
extensions/sftp/client/SFTPClient.cpp:602
↓ 2 callersMethodreservePayloads
libminifi/include/c2/C2Payload.h:183
↓ 2 callersMethodreset
libminifi/include/io/CRCStream.h:69
↓ 2 callersFunctionresolve
libminifi/include/utils/file/FileUtils.h:749
↓ 2 callersMethodreturnEmptyS3Result
libminifi/test/aws-tests/MockS3Wrapper.h:86
↓ 2 callersMethodrm_out_child
(self, dir)
docker/test/integration/minifi/core/DockerTestCluster.py:201
↓ 2 callersMethodrun
extensions/rocksdb-repos/FlowFileRepository.cpp:115
↓ 2 callersMethodrun
extensions/standard-processors/processors/ListenSyslog.cpp:101
↓ 2 callersMethodserialize
extensions/mqtt/protocol/MQTTC2Protocol.cpp:81
↓ 2 callersMethodsetAccessKey
extensions/aws/AWSCredentialsProvider.cpp:47
↓ 2 callersMethodsetAgentIdentificationProvider
libminifi/include/core/state/nodes/AgentInformation.h:507
↓ 2 callersMethodsetBatchSize
setBatchSize
libminifi/include/sitetosite/RawSocketProtocol.h:100
↓ 2 callersMethodsetBookmark
extensions/openwsman/processors/SourceInitiatedSubscriptionListener.cpp:190
↓ 2 callersMethodsetContainer
libminifi/include/c2/C2Payload.h:177
↓ 2 callersMethodsetCredentialsFile
extensions/aws/AWSCredentialsProvider.cpp:55
↓ 2 callersMethodsetDynamicProperties
()
extensions/jni/nifi-framework-jni/src/main/java/org/apache/nifi/processor/JniComponent.java:84
↓ 2 callersMethodsetEnabled
libminifi/src/core/logging/Logger.cpp:42
↓ 2 callersMethodsetFeed
extensions/http-curl/tests/HTTPHandlers.h:204
↓ 2 callersMethodsetFlowIdentifier
* Sets the flow version for this connectable. */
libminifi/include/core/Connectable.h:145
↓ 2 callersMethodsetFlowVersion
libminifi/include/core/state/nodes/FlowInformation.h:99
↓ 2 callersMethodsetHTTPProxy
extensions/http-curl/client/HTTPClient.h:225
↓ 2 callersFunctionsetHostName
nanofi/include/sitetosite/CPeer.h:60
↓ 2 callersMethodsetLineageIdentifiers
libminifi/include/core/FlowFile.h:127
↓ 2 callersMethodsetLineageStartDate
libminifi/src/core/FlowFile.cpp:195
↓ 2 callersMethodsetMaxQueueDataSize
Set Max Queue Data Size
libminifi/include/Connection.h:119
↓ 2 callersMethodsetPenalizationPeriodMsec
Set Processor penalization period in MilliSecond
libminifi/include/core/Processor.h:150
↓ 2 callersFunctionsetPort
nanofi/include/sitetosite/CPeer.h:87
↓ 2 callersFunctionsetPortId
nanofi/include/sitetosite/CRawSocketProtocol.h:146
↓ 2 callersMethodsetProperty
* Sets the property using the provided name * @param property name * @param value property value. * @return result of setting property. */
libminifi/src/core/ConfigurableComponent.cpp:68
↓ 2 callersMethodsetPropertyModifiedCallback
libminifi/test/unit/PropertyValidationTests.cpp:100
↓ 2 callersMethodsetReadCallback
extensions/http-curl/client/HTTPClient.cpp:180
↓ 2 callersMethodsetRemotePort
nanofi/include/cxx/Instance.h:115
↓ 2 callersMethodsetSSLContextService
libminifi/include/sitetosite/SiteToSiteClient.h:82
↓ 2 callersMethodsetSchedulingPeriodNano
Set Processor Scheduling Period in Nano Second
libminifi/include/core/Processor.h:104
↓ 2 callersMethodsetSecretKey
extensions/aws/AWSCredentialsProvider.cpp:51
↓ 2 callersMethodsetState
libminifi/include/core/controller/ControllerService.h:127
↓ 2 callersMethodsetStream
libminifi/include/sitetosite/Peer.h:283
↓ 2 callersFunctionsetSyslogLogger
main/MainHelper.cpp:86
↓ 2 callersMethodsetTimeOut
setTimeOut
libminifi/include/core/ProcessGroup.h:89
↓ 2 callersMethodsetTransportProtocol
libminifi/include/core/ProcessGroup.h:102
↓ 2 callersMethodsetTriggerWhenEmpty
Set Trigger when empty
libminifi/include/core/Processor.h:163
↓ 2 callersMethodsetUUID
Set UUID
libminifi/src/core/Core.cpp:30
↓ 2 callersMethodsetUrl
extensions/http-curl/tests/VerifyInvokeHTTPTest.cpp:47
↓ 2 callersMethodsetUseDefaultCredentials
extensions/aws/AWSCredentialsProvider.cpp:43
↓ 2 callersMethodsetValue
extensions/standard-processors/processors/PutFile.h:124
↓ 2 callersMethodsetVerbose
extensions/sftp/client/SFTPClient.cpp:172
↓ 2 callersFunctionset_failure_strategy
nanofi/src/api/nanofi.cpp:584
↓ 2 callersFunctionset_propery_internal
nanofi/src/api/nanofi.cpp:588
↓ 2 callersMethodshortenClassNames
libminifi/include/core/logging/LoggerConfiguration.h:116
↓ 2 callersMethodsize
libminifi/include/io/FileStream.h:68
↓ 2 callersMethodstart_flow
(self, name)
docker/test/integration/minifi/core/DockerTestCluster.py:83
↓ 2 callersFunctionstopComponent
* Stops a stopped component * @param socket socket unique ptr. * @param op operation to perform */
controller/Controller.h:47
↓ 2 callersMethodstopProcessing
libminifi/src/core/ProcessGroup.cpp:216
↓ 2 callersMethodstop_flow
(self, name)
docker/test/integration/minifi/core/DockerTestCluster.py:93
↓ 2 callersFunctionstop_kafka
()
docker/test/integration/test_rdkafka.py:68
↓ 2 callersMethodsubscribeToTopic
extensions/mqtt/controllerservice/MQTTControllerService.h:165
↓ 2 callersMethodswap
libminifi/include/utils/FlatMap.h:245
↓ 2 callersMethodtestAndSetKey
* A test and set operation, which is used to allow a function to test * if an item can be released and a function used for reclaiming memory associ
libminifi/include/core/repository/AtomicRepoEntries.h:226
↓ 2 callersFunctiontestIsSubsetOf
libminifi/test/unit/ExtendedKeyUsageTests.cpp:65
↓ 2 callersMethodtimeSinceEpoch
libminifi/include/utils/TimeUtil.h:67
↓ 2 callersMethodtoJsonString
extensions/libarchive/ArchiveMetadata.cpp:201
← previousnext →1,101–1,200 of 5,249, ranked by callers