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
↓ 39 callers
Function
getTimeMillis
* Gets the current time in milliseconds * @returns milliseconds since epoch */
libminifi/include/utils/TimeUtil.h:44
↓ 39 callers
Method
join
libminifi/src/provenance/Provenance.cpp:453
↓ 38 callers
Function
StringToTime
libminifi/include/utils/ValueParser.h:161
↓ 37 callers
Method
begin
libminifi/test/archive-tests/MergeFileTests.cpp:79
↓ 37 callers
Method
getInterface
libminifi/include/core/ProcessGroup.h:99
↓ 37 callers
Method
getResourceClaim
libminifi/src/core/FlowFile.cpp:92
↓ 37 callers
Method
poll
libminifi/src/Connection.cpp:181
↓ 36 callers
Method
clear
libminifi/src/controllers/keyvalue/AbstractCoreComponentStateManagerProvider.cpp:63
↓ 36 callers
Method
create
libminifi/src/core/ContentSession.cpp:35
↓ 36 callers
Method
end
libminifi/test/archive-tests/MergeFileTests.cpp:80
↓ 36 callers
Function
getUUIDStr
nanofi/include/sitetosite/CSiteToSite.h:317
↓ 35 callers
Method
WriteNChars
nanofi/tests/CTestsBase.h:56
↓ 35 callers
Method
commit
libminifi/src/core/ContentSession.cpp:69
↓ 35 callers
Function
createRepository
libminifi/src/core/RepositoryFactory.cpp:36
↓ 35 callers
Method
what
extensions/script/ScriptException.h:49
↓ 34 callers
Method
asBoolean
extensions/expression-language/common/Value.h:222
↓ 34 callers
Method
getProcessorNode
Get Processor associated with the Process Context
libminifi/include/core/ProcessContext.h:96
↓ 33 callers
Method
encode
encode uint32_t
libminifi/include/FlowControlProtocol.h:224
↓ 33 callers
Function
tearDown
nanofi/src/sitetosite/CRawSocketProtocol.c:865
↓ 33 callers
Method
to_string
libminifi/test/archive-tests/MergeFileTests.cpp:82
↓ 32 callers
Method
create
extensions/script/lua/LuaProcessSession.cpp:96
↓ 32 callers
Method
get
extensions/http-curl/tests/TimeoutHTTPSiteToSiteTests.cpp:83
↓ 32 callers
Method
getName
()
extensions/sftp/tests/tools/sftp-test-server/src/main/java/InsecureRandom.java:34
↓ 32 callers
Method
setAttribute
extensions/script/ScriptFlowFile.cpp:55
↓ 31 callers
Function
create_dir
libminifi/include/utils/file/FileUtils.h:354
↓ 31 callers
Function
get_executable_dir
* Returns the absolute path to the directory containing the current executable */
libminifi/include/utils/file/FileUtils.h:759
↓ 31 callers
Method
get_next_client_response
libminifi/test/unit/SiteToSiteHelper.h:50
↓ 31 callers
Method
load
libminifi/test/unit/ProvenanceTestHelper.h:249
↓ 31 callers
Method
read
libminifi/test/archive-tests/MergeFileTests.cpp:114
↓ 31 callers
Method
write
libminifi/include/io/AtomicEntryStream.h:113
↓ 31 callers
Method
yield
extensions/coap/server/CoapServer.h:197
↓ 30 callers
Method
check_output
Wait for flow output, validate it, and log minifi output.
docker/test/integration/minifi/core/DockerTestCluster.py:166
↓ 30 callers
Method
incrementActiveTasks
Increment Active Task Counts
libminifi/include/core/Processor.h:175
↓ 29 callers
Method
get
extensions/standard-processors/controllers/UnorderedMapKeyValueStoreService.cpp:46
↓ 29 callers
Method
getName
* Gets the name of the object. * @return class name of processor */
extensions/libarchive/ArchiveLoader.h:36
↓ 29 callers
Method
getPort
extensions/sftp/tests/tools/SFTPTestServer.cpp:145
↓ 29 callers
Method
read
libminifi/include/io/AtomicEntryStream.h:132
↓ 29 callers
Method
yield
extensions/sql/services/DatabaseService.h:65
↓ 28 callers
Method
addRelationship
Set Connection relationship
libminifi/include/Connection.h:103
↓ 28 callers
Method
generate
main/AgentDocs.cpp:54
↓ 28 callers
Method
write
libminifi/src/core/ContentSession.cpp:41
↓ 27 callers
Function
free_flowfile
* Reclaims memory associated with a flow file object * @param ff flow file record. */
nanofi/src/api/nanofi.cpp:342
↓ 27 callers
Method
getBuffer
libminifi/include/io/Stream.h:42
↓ 27 callers
Method
setUrl
extensions/http-curl/tests/HTTPIntegrationBase.h:72
↓ 27 callers
Method
size
* Return the size of the memory within the key * buffer, the size of timestamp, and the general * system word size */
libminifi/include/core/repository/AtomicRepoEntries.h:125
↓ 26 callers
Method
clear
extensions/rocksdb-repos/controllers/RocksDbPersistableKeyValueStoreService.cpp:162
↓ 26 callers
Function
computeChecksum
libminifi/src/utils/file/FileUtils.cpp:32
↓ 26 callers
Method
createPlan
libminifi/test/TestBase.h:350
↓ 26 callers
Method
generate
libminifi/src/utils/Id.cpp:302
↓ 26 callers
Function
get
nanofi/src/api/nanofi.cpp:648
↓ 26 callers
Method
getName
* Gets the name of the object. * @return class name of processor */
extensions/librdkafka/RdKafkaLoader.h:36
↓ 26 callers
Method
isSubsetOf
libminifi/src/utils/tls/ExtendedKeyUsage.cpp:86
↓ 26 callers
Method
put
libminifi/src/Connection.cpp:136
↓ 26 callers
Method
setSourceUUID
Set Source Processor UUID
libminifi/include/Connection.h:61
↓ 25 callers
Function
encode
encode uint32_t
libminifi/test/Server.cpp:141
↓ 25 callers
Method
enqueue
extensions/mqtt/controllerservice/MQTTControllerService.h:241
↓ 25 callers
Method
getCurrentFlowFile
nanofi/src/cxx/Plan.cpp:199
↓ 25 callers
Method
size
extensions/rocksdb-repos/RocksDbStream.h:61
↓ 25 callers
Method
stop
* Stop the client */
libminifi/test/unit/ControllerTests.cpp:110
↓ 24 callers
Function
createExtendedKeyUsage
libminifi/test/unit/ExtendedKeyUsageTests.cpp:57
↓ 24 callers
Method
getValue
libminifi/include/core/state/Value.h:90
↓ 24 callers
Function
invoke
nanofi/src/api/nanofi.cpp:684
↓ 23 callers
Method
CloseStream
nanofi/tests/CTestsBase.h:70
↓ 23 callers
Function
JniStringToUTF
extensions/jni/JNIUtil.h:25
↓ 23 callers
Method
addPayload
libminifi/src/c2/C2Payload.cpp:83
↓ 23 callers
Method
decode
encode uint32_t
libminifi/include/FlowControlProtocol.h:233
↓ 23 callers
Function
flow_files_size
nanofi/src/core/flowfiles.c:155
↓ 23 callers
Method
getEvents
Get events
libminifi/include/provenance/Provenance.h:463
↓ 23 callers
Method
getName
* Gets the name of the object. * @return class name of processor */
extensions/coap/COAPLoader.h:51
↓ 23 callers
Method
put
extensions/libarchive/BinFiles.cpp:353
↓ 23 callers
Method
setKeyDir
libminifi/test/integration/IntegrationBase.h:44
↓ 22 callers
Method
find
libminifi/test/unit/CollectionUtilsTests.cpp:48
↓ 22 callers
Method
get
extensions/script/lua/LuaProcessSession.cpp:32
↓ 22 callers
Method
getName
Get Name for the relationship
libminifi/include/core/Relationship.h:65
↓ 22 callers
Method
getName
* Gets the name of the object. * @return class name of processor */
extensions/mqtt/MQTTLoader.h:37
↓ 22 callers
Method
onTrigger
OnTrigger method, implemented by NiFi Processor Designer
libminifi/test/unit/MockClasses.h:96
↓ 22 callers
Method
yield
libminifi/src/controllers/NetworkPrioritizerService.cpp:77
↓ 21 callers
Method
addAttribute
libminifi/src/core/FlowFile.cpp:184
↓ 21 callers
Function
appendTempFile
extensions/standard-processors/tests/unit/TailFileTests.cpp:59
↓ 21 callers
Method
empty
libminifi/include/core/state/Value.h:64
↓ 21 callers
Method
enqueue
libminifi/include/utils/MinifiConcurrentQueue.h:85
↓ 21 callers
Method
flushContent
libminifi/src/core/ProcessSession.cpp:957
↓ 21 callers
Method
get
(final String key)
extensions/jni/nifi-framework-jni/src/main/java/org/apache/nifi/processor/JniStateMap.java:24
↓ 21 callers
Method
getProvenanceRecords
nanofi/src/cxx/Plan.cpp:195
↓ 21 callers
Function
get_parent_path
libminifi/include/utils/file/FileUtils.h:676
↓ 21 callers
Method
initialize
extensions/gps/GetGPS.cpp:61
↓ 21 callers
Function
intdiv_ceil
libminifi/include/utils/GeneralUtils.h:45
↓ 21 callers
Function
invoke_processor
nanofi/tests/CTestsBase.h:151
↓ 21 callers
Method
onSchedule
libminifi/test/flow-tests/CustomProcessors.h:78
↓ 21 callers
Method
serialize
libminifi/src/serialization/PayloadSerializer.cpp:27
↓ 21 callers
Method
setSource
Set Connection Source Processor
libminifi/include/Connection.h:78
↓ 21 callers
Function
set_standalone_property
nanofi/src/api/nanofi.cpp:599
↓ 20 callers
Method
createSocket
libminifi/src/io/StreamFactory.cpp:59
↓ 20 callers
Method
getLabel
libminifi/include/c2/C2Payload.h:131
↓ 20 callers
Function
getStringValue
libminifi/src/core/reporting/SiteToSiteProvenanceReportingTask.cpp:72
↓ 20 callers
Function
last_write_time
libminifi/include/utils/file/FileUtils.h:240
↓ 20 callers
Method
load
extensions/standard-processors/controllers/UnorderedMapPersistableKeyValueStoreService.cpp:217
↓ 20 callers
Method
onTrigger
* Execution trigger for the GetFile Processor * @param context processor context * @param session processor session reference. */
extensions/standard-processors/tests/unit/ProcessorTests.cpp:524
↓ 20 callers
Function
reportEvent
extensions/windows-event-log/tests/ConsumeWindowsEventLogTests.cpp:38
↓ 19 callers
Method
add
extensions/windows-event-log/SupportedProperty.h:67
← previous
next →
101–200 of 5,249, ranked by callers