Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/apache/nifi-minifi-cpp
/ functions
Functions
5,249 in github.com/apache/nifi-minifi-cpp
⨍
Functions
5,249
◇
Types & classes
1,209
↓ 1 callers
Function
make_allDelineatedValues
extensions/expression-language/Expression.cpp:1279
↓ 1 callers
Function
make_allMatchingAttributes
extensions/expression-language/Expression.cpp:1171
↓ 1 callers
Function
make_anyAttribute
extensions/expression-language/Expression.cpp:1124
↓ 1 callers
Function
make_anyDelineatedValue
extensions/expression-language/Expression.cpp:1311
↓ 1 callers
Function
make_anyMatchingAttribute
extensions/expression-language/Expression.cpp:1224
↓ 1 callers
Function
make_count
extensions/expression-language/Expression.cpp:1343
↓ 1 callers
Function
make_dynamic_function
extensions/expression-language/Expression.cpp:1401
↓ 1 callers
Function
make_join
extensions/expression-language/Expression.cpp:1368
↓ 1 callers
Function
mapped_distro
()
bootstrap.py:81
↓ 1 callers
Method
matches
extensions/http-curl/client/HTTPClient.cpp:374
↓ 1 callers
Method
max_size
libminifi/include/utils/FlatMap.h:254
↓ 1 callers
Method
merge
extensions/libarchive/MergeContent.cpp:353
↓ 1 callers
Function
monitor_directory
* Monitor directory can be combined into a current flow. to create an execution plan */
nanofi/include/blocks/file_blocks.h:30
↓ 1 callers
Method
moveStateFileToMigrated
extensions/sql/processors/QueryDatabaseTable.cpp:132
↓ 1 callers
Method
newInstance
* Call empty constructor */
extensions/jni/jvm/NarClassLoader.h:178
↓ 1 callers
Method
nifi_property_key
Returns the Apache NiFi-equivalent property key for the given key. This is often, but not always, the same as the internal key.
docker/test/integration/minifi/core/Processor.py:40
↓ 1 callers
Function
nodeValue2String
extensions/opc/src/opc.cpp:479
↓ 1 callers
Method
notifyPullTracesDone
libminifi/include/utils/BackTrace.h:155
↓ 1 callers
Method
onEnable
extensions/jni/jvm/JavaControllerService.cpp:78
↓ 1 callers
Method
onInitialize
extensions/script/python/PythonScriptEngine.h:173
↓ 1 callers
Method
onSchedule
libminifi/test/KamikazeProcessor.cpp:54
↓ 1 callers
Method
onSchedule
libminifi/src/RemoteProcessorGroupPort.cpp:138
↓ 1 callers
Function
onTrigger
(context, session)
extensions/script/ExampleProcessor.py:22
↓ 1 callers
Method
onTrigger
libminifi/test/persistence-tests/PersistenceTests.cpp:247
↓ 1 callers
Method
onTrigger
extensions/script/ExecuteScript.h:55
↓ 1 callers
Method
onUnSchedule
libminifi/test/KamikazeProcessor.cpp:76
↓ 1 callers
Function
openPeer
nanofi/src/sitetosite/CPeer.c:24
↓ 1 callers
Function
parseAnnotatedValue
libminifi/src/c2/protocols/RESTProtocol.cpp:43
↓ 1 callers
Function
parseDelimiter
the delimiter is the first character of the input, allowing some escape sequences
extensions/standard-processors/processors/TailFile.cpp:143
↓ 1 callers
Function
parseLocationName
libminifi/src/utils/tls/WindowsCertStoreLocation.cpp:45
↓ 1 callers
Method
persist
extensions/rocksdb-repos/controllers/RocksDbPersistableKeyValueStoreService.cpp:196
↓ 1 callers
Method
persist
extensions/standard-processors/controllers/UnorderedMapKeyValueStoreService.h:60
↓ 1 callers
Method
persistImpl
libminifi/src/controllers/keyvalue/PersistableKeyValueStoreService.cpp:63
↓ 1 callers
Method
persistState
extensions/openwsman/processors/SourceInitiatedSubscriptionListener.cpp:202
↓ 1 callers
Method
pop
* Returns a response if one exists. */
extensions/coap/controllerservice/CoapMessaging.h:52
↓ 1 callers
Function
printManifest
controller/Controller.h:283
↓ 1 callers
Method
process
extensions/http-curl/client/HTTPCallback.h:81
↓ 1 callers
Method
process
extensions/librdkafka/PublishKafka.cpp:385
↓ 1 callers
Method
processBin
Processes a single bin.
extensions/libarchive/BinFiles.h:267
↓ 1 callers
Method
processColumnName
extensions/sql/data/JSONSQLWriter.cpp:46
↓ 1 callers
Method
processOnSchedule
extensions/sql/processors/PutSQL.cpp:75
↓ 1 callers
Method
processOnTrigger
extensions/sql/processors/PutSQL.cpp:81
↓ 1 callers
Method
processOne
extensions/sftp/processors/PutSFTP.cpp:223
↓ 1 callers
Method
prune
extensions/jni/jvm/JniReferenceObjects.h:271
↓ 1 callers
Method
put
* Puts the service node into the mapping using <code>id</code> as the identifier * @param id service identifier * @param serviceNode controller
libminifi/include/core/controller/ControllerServiceMap.h:83
↓ 1 callers
Method
putField
extensions/jni/jvm/JVMLoader.h:62
↓ 1 callers
Method
putFile
extensions/sftp/client/SFTPClient.cpp:538
↓ 1 callers
Function
putFileToDir
libminifi/include/utils/TestUtils.h:42
↓ 1 callers
Method
putObject
extensions/aws/s3/S3WrapperBase.cpp:102
↓ 1 callers
Method
putTopic
extensions/librdkafka/KafkaConnection.cpp:94
↓ 1 callers
Method
put_test_resource
Creates a resource file in the test resource dir and writes the given content to it.
docker/test/integration/minifi/core/DockerTestCluster.py:114
↓ 1 callers
Function
queryEvents
extensions/windows-event-log/tests/BookmarkTests.cpp:71
↓ 1 callers
Method
readFully
libminifi/src/utils/ByteArrayCallback.cpp:103
↓ 1 callers
Function
readOptionalInt64
extensions/standard-processors/processors/TailFile.cpp:123
↓ 1 callers
Function
readOptionalUint64
extensions/standard-processors/processors/TailFile.cpp:133
↓ 1 callers
Function
readYAML
libminifi/test/Server.cpp:283
↓ 1 callers
Function
read_payload_and_transmit
nanofi/src/core/flowfiles.c:85
↓ 1 callers
Function
read_uint16_t
nanofi/src/core/cstream.c:124
↓ 1 callers
Method
receive
libminifi/src/sitetosite/SiteToSiteClient.cpp:531
↓ 1 callers
Method
reduce
libminifi/src/controllers/LinuxPowerManagementService.cpp:89
↓ 1 callers
Method
registerMethods
extensions/jni/jvm/JavaClass.h:104
↓ 1 callers
Method
registerResource
libminifi/include/core/FlowConfiguration.h:166
↓ 1 callers
Method
releaseCoreResources
extensions/script/lua/LuaProcessSession.cpp:123
↓ 1 callers
Method
remove
Remove event
libminifi/include/provenance/Provenance.h:471
↓ 1 callers
Method
remove
extensions/rocksdb-repos/DatabaseContentRepository.cpp:146
↓ 1 callers
Method
remove
extensions/jni/jvm/JniReferenceObjects.h:226
↓ 1 callers
Function
removeFile
extensions/standard-processors/tests/unit/TailFileTests.cpp:64
↓ 1 callers
Method
removeImpl
libminifi/src/controllers/keyvalue/PersistableKeyValueStoreService.cpp:59
↓ 1 callers
Method
removeOldestBin
extensions/libarchive/BinFiles.cpp:175
↓ 1 callers
Function
remove_last_node
nanofi/src/core/string_utils.c:79
↓ 1 callers
Method
reset
libminifi/test/TestBase.h:167
↓ 1 callers
Function
resolve_address
extensions/coap/nanofi/coap_functions.c:174
↓ 1 callers
Method
restart_observer_if_needed
(self)
docker/test/integration/minifi/core/DockerTestCluster.py:123
↓ 1 callers
Method
rollback
()
extensions/jni/nifi-framework-jni/src/main/java/org/apache/nifi/processor/JniProcessSession.java:25
↓ 1 callers
Method
run
libminifi/src/core/repository/VolatileContentRepository.cpp:67
↓ 1 callers
Method
run
extensions/coap/tests/CoapIntegrationBase.h:47
↓ 1 callers
Method
runAssertions
extensions/http-curl/tests/VerifyInvokeHTTPTest.cpp:146
↓ 1 callers
Method
runThread
extensions/standard-processors/processors/ListenSyslog.cpp:105
↓ 1 callers
Method
seedTempPaths
extensions/libarchive/ArchiveMetadata.cpp:151
↓ 1 callers
Method
send
libminifi/src/provenance/Provenance.cpp:504
↓ 1 callers
Method
send
libminifi/src/sitetosite/SiteToSiteClient.cpp:413
↓ 1 callers
Method
sendKeepAliveIfNeeded
extensions/sftp/client/SFTPClient.cpp:449
↓ 1 callers
Function
sendPacket
nanofi/src/sitetosite/CRawSocketProtocol.c:656
↓ 1 callers
Method
sendPayload
extensions/coap/controllerservice/CoapConnector.cpp:76
↓ 1 callers
Method
sendRegisterReq
libminifi/src/FlowControlProtocol.cpp:154
↓ 1 callers
Method
sendReportReq
libminifi/src/FlowControlProtocol.cpp:257
↓ 1 callers
Function
send_pdu
extensions/coap/nanofi/coap_connection.c:104
↓ 1 callers
Method
serialize
libminifi/include/core/state/nodes/FlowInformation.h:104
↓ 1 callers
Method
serialize
(self, connectable, root=None, visited=None)
docker/test/integration/minifi/flow_serialization/Minifi_flow_yaml_serializer.py:8
↓ 1 callers
Method
serialize
(self, connectable, nifi_version=None, root=None, visited=None)
docker/test/integration/minifi/flow_serialization/Nifi_flow_xml_serializer.py:10
↓ 1 callers
Method
setAttributes
extensions/sftp/client/SFTPClient.cpp:745
↓ 1 callers
Method
setBase
(self, proc)
python/minifi/__init__.py:71
↓ 1 callers
Method
setBaseServicer
extensions/jni/jvm/JVMLoader.h:278
↓ 1 callers
Method
setBinAge
extensions/libarchive/BinFiles.h:165
↓ 1 callers
Method
setC2Url
extensions/http-curl/tests/HTTPIntegrationBase.h:112
↓ 1 callers
Method
setCollapsible
libminifi/include/c2/C2Payload.h:174
↓ 1 callers
Method
setConfiguration
* Replaces the configuration object within the controller service. */
libminifi/include/core/controller/ControllerService.h:107
↓ 1 callers
Method
setConnection
extensions/librdkafka/KafkaConnection.cpp:64
↓ 1 callers
Method
setContainers
libminifi/include/core/Repository.h:123
↓ 1 callers
Method
setControllerServiceProvider
libminifi/include/utils/ThreadPool.h:285
← previous
next →
1,601–1,700 of 5,249, ranked by callers