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
↓ 12 callers
Method
start
libminifi/src/c2/C2Agent.cpp:90
↓ 12 callers
Function
stringToBytes
libminifi/src/utils/EncryptionUtils.cpp:34
↓ 11 callers
Method
appendHeader
extensions/http-curl/client/HTTPClient.cpp:235
↓ 11 callers
Method
asUnsignedLong
extensions/expression-language/common/Value.h:180
↓ 11 callers
Method
commit
extensions/sql/data/DatabaseConnectors.h:70
↓ 11 callers
Method
createSecureSocket
libminifi/src/io/StreamFactory.cpp:64
↓ 11 callers
Function
flatMap
libminifi/include/utils/OptionalUtils.h:88
↓ 11 callers
Method
getBuffer
extensions/http-curl/client/HTTPCallback.h:107
↓ 11 callers
Method
getContent
extensions/http-curl/tests/unit/HTTPStreamingCallbackTests.cpp:72
↓ 11 callers
Method
getCurrentFlowFile
libminifi/test/TestBase.cpp:309
↓ 11 callers
Method
getDirection
getDirection
libminifi/include/sitetosite/SiteToSite.h:282
↓ 11 callers
Function
getFullPath
libminifi/src/utils/file/PathUtils.cpp:62
↓ 11 callers
Method
getInterface
* If not an intersecting operation we will attempt to locate the highest priority interface available. */
libminifi/src/controllers/NetworkPrioritizerService.cpp:83
↓ 11 callers
Method
getProvenanceRecords
libminifi/test/TestBase.cpp:305
↓ 11 callers
Method
getString
Get the config value
libminifi/src/properties/Properties.cpp:40
↓ 11 callers
Method
onSchedule
* Function that's executed when the processor is scheduled. * @param context process context. * @param sessionFactory process session factory th
extensions/standard-processors/tests/unit/ProcessorTests.cpp:517
↓ 11 callers
Method
parse
libminifi/src/utils/Id.cpp:144
↓ 11 callers
Method
parseEnd
libminifi/include/utils/ValueParser.h:122
↓ 11 callers
Function
readResponse
nanofi/src/sitetosite/CRawSocketProtocol.c:762
↓ 11 callers
Method
remove
libminifi/src/core/ProcessSession.cpp:179
↓ 11 callers
Method
setResourceClaim
libminifi/src/core/FlowFile.cpp:99
↓ 11 callers
Method
setSize
* Set the size of this record. * @param size size of record to set.Ï */
libminifi/include/core/FlowFile.h:188
↓ 11 callers
Function
sftp_strerror
extensions/sftp/client/SFTPClient.cpp:38
↓ 10 callers
Function
FlowControlMsgIDEncodingLen
FlowControl Protocol Msg Len
libminifi/test/Server.cpp:92
↓ 10 callers
Method
asLongDouble
extensions/expression-language/common/Value.h:208
↓ 10 callers
Method
clear
libminifi/include/core/controller/ControllerServiceMap.h:92
↓ 10 callers
Method
execute
libminifi/src/utils/ThreadPool.cpp:101
↓ 10 callers
Method
flush
libminifi/test/rocksdb-tests/RepoTests.cpp:357
↓ 10 callers
Function
free_standalone_processor
nanofi/src/api/nanofi.cpp:181
↓ 10 callers
Method
getControllerService
(String serviceIdentifier)
extensions/jni/nifi-framework-jni/src/main/java/org/apache/nifi/processor/JniProcessContext.java:21
↓ 10 callers
Method
getControllerServiceNode
* Gets the controller service node using the <code>id</code> * @param id identifier for controller service. * @return nullptr if node does not e
libminifi/include/core/controller/ControllerServiceMap.h:54
↓ 10 callers
Method
getFilePath
nanofi/tests/CTestsBase.h:62
↓ 10 callers
Method
getId
()
extensions/jni/nifi-framework-jni/src/main/java/org/apache/nifi/processor/JniFlowFile.java:14
↓ 10 callers
Method
getKey
libminifi/include/properties/PropertiesFile.h:41
↓ 10 callers
Method
getName
* Gets the name of the object. * @return class name of processor */
extensions/script/pythonloader/PyProcLoader.h:36
↓ 10 callers
Method
getOffset
! Get Offset
libminifi/src/core/FlowFile.cpp:160
↓ 10 callers
Function
get_attribute
* Obtains the attribute. * @param ff flow file record * @param key key * @param caller_attribute caller supplied object in which we will copy the d
nanofi/src/api/nanofi.cpp:400
↓ 10 callers
Function
get_last_socket_error_message
libminifi/src/io/ClientSocket.cpp:143
↓ 10 callers
Function
get_next_flow_file
nanofi/src/api/nanofi.cpp:660
↓ 10 callers
Method
isDecimal
extensions/expression-language/common/Value.h:88
↓ 10 callers
Method
loadClass
extensions/jni/jvm/JavaControllerService.h:92
↓ 10 callers
Method
name
libminifi/src/utils/EncryptionUtils.cpp:54
↓ 10 callers
Method
pop
extensions/libarchive/ArchiveMetadata.h:87
↓ 10 callers
Method
read
libminifi/src/core/ContentSession.cpp:59
↓ 10 callers
Method
registerClasses
extensions/jni/ClassRegistrar.h:55
↓ 10 callers
Function
run_archive_test
libminifi/test/archive-tests/ManipulateArchiveTests.cpp:45
↓ 10 callers
Method
setDescription
extensions/script/python/ExecutePythonProcessor.h:82
↓ 10 callers
Method
setHome
Set the determined MINIFI_HOME
libminifi/include/properties/Properties.h:97
↓ 10 callers
Method
update
extensions/http-curl/protocols/RESTSender.cpp:79
↓ 10 callers
Function
writeData
nanofi/include/sitetosite/CSiteToSite.h:325
↓ 9 callers
Method
build
()
extensions/jni/nifi-framework-jni/src/main/java/org/apache/nifi/processor/JniComponent.java:99
↓ 9 callers
Method
canUpdate
libminifi/include/core/state/UpdatePolicy.h:50
↓ 9 callers
Method
cbegin
libminifi/include/utils/FlatMap.h:218
↓ 9 callers
Method
commit
Renames tmp file to final destination Returns true if commit succeeded
extensions/standard-processors/processors/PutFile.cpp:353
↓ 9 callers
Function
createNetworkPrioritizerService
libminifi/test/unit/NetworkPrioritizerServiceTests.cpp:30
↓ 9 callers
Function
createTempDir
libminifi/include/utils/TestUtils.h:34
↓ 9 callers
Function
create_instance_obj
nanofi/tests/CAPITests.cpp:28
↓ 9 callers
Function
create_processor
nanofi/src/api/nanofi.cpp:134
↓ 9 callers
Method
get
libminifi/src/controllers/keyvalue/AbstractCoreComponentStateManagerProvider.cpp:55
↓ 9 callers
Method
get
extensions/mqtt/controllerservice/MQTTControllerService.h:185
↓ 9 callers
Method
getBufferSize
libminifi/include/core/repository/AtomicRepoEntries.h:129
↓ 9 callers
Method
getChildrenUuids
Get Children UUIDs
libminifi/include/provenance/Provenance.h:286
↓ 9 callers
Method
getName
libminifi/include/core/state/nodes/MetricsBase.h:111
↓ 9 callers
Method
getRoot
libminifi/include/core/FlowConfiguration.h:138
↓ 9 callers
Method
getUUID
* Returns the UUID through the provided object. * @param uuid uuid struct to which we will copy the memory * @return success of request */
libminifi/include/core/ProcessorNode.h:255
↓ 9 callers
Method
getValues
libminifi/src/core/Property.cpp:65
↓ 9 callers
Function
get_proc_uuid_from_processor
nanofi/src/api/nanofi.cpp:172
↓ 9 callers
Function
list_dir
* Provides a platform-independent function to list a directory * Callback is called for every file found: first argument is the path of the directory
libminifi/include/utils/file/FileUtils.h:500
↓ 9 callers
Method
load_class
* Loads a class, creating a global reference to the jclass * @param class name. * @return JavaClass */
extensions/jni/jvm/JVMLoader.h:146
↓ 9 callers
Method
lock
libminifi/include/utils/BackTrace.h:151
↓ 9 callers
Method
modifyResult
extensions/librdkafka/PublishKafka.cpp:251
↓ 9 callers
Function
onSchedule
onSchedule is where you load and read properties this function is called 1 time when the processor is scheduled to run
extensions/pythonprocessors/h2o/h2o3/mojo/ExecuteH2oMojoScoring.py:90
↓ 9 callers
Function
parse_http_components
This function, unfortunately, assumes that we're parsing http components of a local host. On windows this is problematic so we convert localhost to ou
libminifi/include/utils/HTTPUtils.h:29
↓ 9 callers
Method
persist
libminifi/src/core/FlowConfiguration.cpp:97
↓ 9 callers
Method
replace
(final StateMap oldValue, final Map<String, String> newValue, final Scope scope)
extensions/jni/nifi-framework-jni/src/main/java/org/apache/nifi/processor/JniStateManager.java:22
↓ 9 callers
Method
reset
libminifi/src/core/ContentRepository.cpp:36
↓ 9 callers
Method
stop
libminifi/src/c2/C2Agent.cpp:108
↓ 9 callers
Method
toString
extensions/sql/data/JSONSQLWriter.cpp:83
↓ 9 callers
Function
writeRequestType
nanofi/src/sitetosite/CRawSocketProtocol.c:827
↓ 8 callers
Method
NewIterator
extensions/rocksdb-repos/RocksDatabase.cpp:85
↓ 8 callers
Method
add_node
extensions/opc/src/opc.cpp:400
↓ 8 callers
Function
convert
libminifi/include/core/PropertyValue.h:37
↓ 8 callers
Function
create_testfile_for_getfile
nanofi/tests/CAPITests.cpp:83
↓ 8 callers
Function
decode
encode uint32_t
libminifi/test/Server.cpp:150
↓ 8 callers
Function
file_size
libminifi/include/utils/file/FileUtils.h:267
↓ 8 callers
Method
getAttributes
* Returns the map of attributes * @return attributes. */
libminifi/include/core/FlowFile.h:166
↓ 8 callers
Method
getFile
extensions/sftp/client/SFTPClient.cpp:467
↓ 8 callers
Method
getIdentifier
libminifi/include/c2/C2Payload.h:128
↓ 8 callers
Method
getOperation
libminifi/src/c2/protocols/RESTProtocol.cpp:418
↓ 8 callers
Function
getRespondCodeContext
nanofi/include/sitetosite/CRawSocketProtocol.h:87
↓ 8 callers
Method
getSize
extensions/coap/server/CoapServer.h:78
↓ 8 callers
Function
globToRegex
libminifi/src/utils/file/PathUtils.cpp:89
↓ 8 callers
Method
loadConfigureFile
Load Configure File
libminifi/src/properties/Properties.cpp:70
↓ 8 callers
Function
map
libminifi/include/utils/OptionalUtils.h:85
↓ 8 callers
Method
onTrigger
extensions/http-curl/processors/InvokeHTTP.cpp:273
↓ 8 callers
Method
rollback
libminifi/src/core/ContentSession.cpp:97
↓ 8 callers
Method
run
libminifi/src/FlowControlProtocol.cpp:142
↓ 8 callers
Method
setReference
extensions/jni/jvm/JVMLoader.h:235
↓ 8 callers
Function
split_path
libminifi/include/utils/file/FileUtils.h:606
↓ 8 callers
Function
test_lists_equal
nanofi/tests/CLogAggregatorTests.cpp:34
← previous
next →
301–400 of 5,249, ranked by callers