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
↓ 3 callers
Method
getYieldPeriodMsec
Get Processor yield period in MilliSecond
libminifi/include/core/Processor.h:146
↓ 3 callers
Function
get_current_working_directory
nanofi/src/core/file_utils.c:127
↓ 3 callers
Function
get_file_content
libminifi/include/utils/file/FileUtils.h:797
↓ 3 callers
Method
get_keys_of_type
libminifi/src/core/logging/LoggerConfiguration.cpp:63
↓ 3 callers
Method
get_name
(self)
python/minifi/__init__.py:229
↓ 3 callers
Function
get_uid_gid
libminifi/include/utils/file/FileUtils.h:321
↓ 3 callers
Function
getpagesize
libminifi/src/core/ProcessSession.cpp:48
↓ 3 callers
Function
handShake
nanofi/src/sitetosite/CRawSocketProtocol.c:73
↓ 3 callers
Method
handle
extensions/standard-processors/processors/GetTCP.cpp:81
↓ 3 callers
Method
hasIncomingConnections
* @return true if incoming connections > 0 */
libminifi/include/core/Connectable.h:102
↓ 3 callers
Method
incrementStreamCount
libminifi/src/core/ContentRepository.cpp:55
↓ 3 callers
Function
initPeer
nanofi/include/sitetosite/CPeer.h:101
↓ 3 callers
Function
initRawClient
nanofi/include/sitetosite/CRawSocketProtocol.h:171
↓ 3 callers
Method
initialize
nanofi/src/cxx/CallbackProcessor.cpp:29
↓ 3 callers
Method
initialize
libminifi/test/flow-tests/CustomProcessors.h:53
↓ 3 callers
Method
initialize
Initialize, overridden by NiFi Process Designer
libminifi/include/core/Processor.h:242
↓ 3 callers
Function
initialize_content_repo
nanofi/src/api/nanofi.cpp:153
↓ 3 callers
Function
initiateCodecResourceNegotiation
nanofi/src/sitetosite/CRawSocketProtocol.c:934
↓ 3 callers
Function
initiateResourceNegotiation
nanofi/src/sitetosite/CRawSocketProtocol.c:876
↓ 3 callers
Method
insertAfter
libminifi/src/properties/PropertiesFile.cpp:109
↓ 3 callers
Method
invalidateCachedResult
libminifi/include/core/CachedValueValidator.h:111
↓ 3 callers
Method
isArray
libminifi/include/core/state/nodes/MetricsBase.h:69
↓ 3 callers
Method
isFinished
extensions/http-curl/client/HTTPStream.h:118
↓ 3 callers
Function
is_directory
libminifi/include/utils/file/FileUtils.h:332
↓ 3 callers
Method
is_multi
* Whether or not this expression is a multi-expression. */
extensions/expression-language/impl/expression/Expression.h:97
↓ 3 callers
Method
lastReadTimeInMilliseconds
extensions/standard-processors/processors/TailFile.h:57
↓ 3 callers
Function
list_dir_all
libminifi/include/utils/file/FileUtils.h:568
↓ 3 callers
Method
loadJson
extensions/libarchive/ArchiveMetadata.cpp:62
↓ 3 callers
Method
loadJsonString
extensions/libarchive/ArchiveMetadata.cpp:174
↓ 3 callers
Method
onEnable
extensions/sql/services/DatabaseService.cpp:56
↓ 3 callers
Method
onTrigger
libminifi/src/core/Processor.cpp:242
↓ 3 callers
Method
outgoingConnectionsFull
libminifi/src/core/ProcessSession.cpp:961
↓ 3 callers
Function
parse_cmdline_args_with_url
libminifi/test/integration/IntegrationBase.h:198
↓ 3 callers
Function
pipe
libminifi/include/io/StreamPipe.h:48
↓ 3 callers
Function
platform_create_dir
libminifi/include/utils/file/FileUtils.h:105
↓ 3 callers
Method
process
Copy the entire file contents to the temporary file
libminifi/src/core/ProcessSessionReadCallback.cpp:44
↓ 3 callers
Function
provisionRepo
libminifi/test/rocksdb-tests/DBProvenanceRepositoryTests.cpp:41
↓ 3 callers
Method
read
libminifi/test/persistence-tests/PersistenceTests.cpp:108
↓ 3 callers
Method
read
libminifi/src/core/ProcessSession.cpp:281
↓ 3 callers
Method
read
()
extensions/jni/nifi-framework-jni/src/main/java/org/apache/nifi/processor/JniInputStream.java:10
↓ 3 callers
Function
readHdr
libminifi/test/Server.cpp:258
↓ 3 callers
Method
receive
(FlowFile flowFile, String transitUri)
extensions/jni/nifi-framework-jni/src/main/java/org/apache/nifi/processor/JniProvenanceReporter.java:9
↓ 3 callers
Method
reduce_tokens
libminifi/src/controllers/NetworkPrioritizerService.cpp:175
↓ 3 callers
Method
registerCallback
* Initializes the socket * @return result of the creation operation. */
libminifi/src/io/ServerSocket.cpp:59
↓ 3 callers
Method
registerResource
libminifi/src/core/ClassLoader.cpp:36
↓ 3 callers
Method
remove
extensions/standard-processors/controllers/UnorderedMapKeyValueStoreService.cpp:63
↓ 3 callers
Method
removeFile
extensions/sftp/client/SFTPClient.cpp:667
↓ 3 callers
Function
remove_attribute
* Removes a key from the attribute chain * @param ff flow file record * @param key key to remove * @return 0 if removed, -1 otherwise */
nanofi/src/api/nanofi.cpp:443
↓ 3 callers
Method
restore
extensions/libarchive/BinFiles.cpp:348
↓ 3 callers
Method
rollback
extensions/sql/data/DatabaseConnectors.h:74
↓ 3 callers
Method
saveBookmarkXml
extensions/windows-event-log/Bookmark.cpp:113
↓ 3 callers
Method
seek
libminifi/include/utils/ByteArrayCallback.h:59
↓ 3 callers
Method
seek
extensions/http-curl/client/HTTPStream.cpp:54
↓ 3 callers
Function
sendSingleCommand
* Sends a single argument comment * @param socket socket unique ptr. * @param op operation to perform * @param value value to send */
controller/Controller.h:33
↓ 3 callers
Function
send_response_code
nanofi/tests/CSite2SiteTests.cpp:90
↓ 3 callers
Method
setCallback
nanofi/include/cxx/Plan.h:186
↓ 3 callers
Method
setConnectionMap
libminifi/include/core/Repository.h:119
↓ 3 callers
Method
setDataAvailable
setDataAvailable()
libminifi/include/sitetosite/SiteToSite.h:278
↓ 3 callers
Method
setLinkedControllerServices
libminifi/include/core/controller/ControllerService.h:138
↓ 3 callers
Method
setMaxQueueSize
Set Max Queue Size
libminifi/include/Connection.h:111
↓ 3 callers
Method
setProperty
Sets the property value using the property's string name
libminifi/include/core/ProcessContext.h:118
↓ 3 callers
Method
setProperty
libminifi/include/core/state/UpdatePolicy.h:80
↓ 3 callers
Method
setSecurityContext
libminifi/include/sitetosite/SiteToSite.h:350
↓ 3 callers
Method
setStateMonitor
libminifi/include/core/state/nodes/AgentInformation.h:531
↓ 3 callers
Method
setSupportsDynamicProperties
extensions/script/python/PythonProcessor.cpp:38
↓ 3 callers
Method
setSupportsExpressionLanguage
libminifi/src/core/Property.cpp:73
↓ 3 callers
Method
setTransient
libminifi/include/core/Property.h:105
↓ 3 callers
Method
setTransitUri
Set TransitUri
libminifi/include/provenance/Provenance.h:251
↓ 3 callers
Method
setTransmitting
SetTransmitting
libminifi/include/core/ProcessGroup.h:81
↓ 3 callers
Method
setURL
Set URL
libminifi/include/core/ProcessGroup.h:73
↓ 3 callers
Method
setUploadCallback
extensions/http-curl/client/HTTPClient.cpp:186
↓ 3 callers
Method
setUseChunkedEncoding
extensions/http-curl/client/HTTPClient.cpp:245
↓ 3 callers
Method
setYieldPeriodMsec
Set Processor yield period in MilliSecond
libminifi/include/core/Processor.h:142
↓ 3 callers
Function
set_permissions
libminifi/include/utils/file/FileUtils.h:309
↓ 3 callers
Method
set_request_method
extensions/http-curl/client/HTTPClient.cpp:338
↓ 3 callers
Function
setup_nifi_processor
nanofi/src/api/ecu.c:109
↓ 3 callers
Function
setup_signal_action
nanofi/src/api/ecu.c:101
↓ 3 callers
Function
sockaddr_ntop
libminifi/src/io/ClientSocket.cpp:63
↓ 3 callers
Method
stop
libminifi/src/core/Repository.cpp:44
↓ 3 callers
Method
stop
extensions/sftp/tests/tools/SFTPTestServer.cpp:119
↓ 3 callers
Method
stopTasks
libminifi/src/utils/ThreadPool.cpp:197
↓ 3 callers
Method
takeOwnership
libminifi/include/core/repository/AtomicRepoEntries.h:209
↓ 3 callers
Function
testMultiplesLogAttribute
extensions/standard-processors/tests/unit/ProcessorTests.cpp:350
↓ 3 callers
Method
toMap
()
extensions/jni/nifi-framework-jni/src/main/java/org/apache/nifi/processor/JniStateMap.java:29
↓ 3 callers
Function
to_wstring
extensions/windows-event-log/wel/UnicodeConversion.h:38
↓ 3 callers
Function
transmitPayload
nanofi/src/sitetosite/CRawSocketProtocol.c:390
↓ 3 callers
Function
transmit_payload
nanofi/src/core/flowfiles.c:143
↓ 3 callers
Method
unique_file
libminifi/include/utils/file/FileManager.h:69
↓ 3 callers
Method
unpack
Unpacks the NAR to the specified directory. Creates a checksum file that used to determine if future expansion is necessary. @param workingDirectory
extensions/jni/nifi-framework-jni/src/main/java/org/apache/nifi/nar/JniUnpacker.java:187
↓ 3 callers
Method
update
libminifi/src/properties/PropertiesFile.cpp:100
↓ 3 callers
Method
updatePropertyValue
libminifi/src/core/ProcessGroup.cpp:301
↓ 3 callers
Function
update_curr_offset
nanofi/src/api/ecu.c:202
↓ 3 callers
Function
validate_input_params
nanofi/src/api/ecu.c:65
↓ 3 callers
Function
verifyWithBusyWait
libminifi/test/flow-tests/FlowControllerTests.cpp:93
↓ 3 callers
Function
wait_until
nanofi/tests/CSite2SiteTests.cpp:64
↓ 3 callers
Method
withAllowableValues
libminifi/include/core/Property.h:454
↓ 3 callers
Method
withType
libminifi/include/core/Property.h:440
↓ 3 callers
Method
write
libminifi/test/archive-tests/MergeFileTests.cpp:87
↓ 2 callers
Method
Close
libminifi/src/sitetosite/Peer.cpp:66
↓ 2 callers
Method
Delete
libminifi/test/unit/ProvenanceTestHelper.h:96
← previous
next →
801–900 of 5,249, ranked by callers