Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1191 - 1200 of 6,703 for RETURN (0.07 sec)

  1. internal/event/target/kafka.go

    		if target.batch != nil {
    			return target.batch.Add(eventData)
    		}
    		_, err := target.store.Put(eventData)
    		return err
    	}
    	if err := target.init(); err != nil {
    		return err
    	}
    	return target.send(eventData)
    }
    
    // send - sends an event to the kafka.
    func (target *KafkaTarget) send(eventData event.Event) error {
    	if target.producer == nil {
    		return store.ErrNotConnected
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  2. guava/src/com/google/common/collect/ImmutableRangeSet.java

      public ImmutableSet<Range<C>> asRanges() {
        if (ranges.isEmpty()) {
          return ImmutableSet.of();
        }
        return new RegularImmutableSortedSet<>(ranges, Range.<C>rangeLexOrdering());
      }
    
      @Override
      public ImmutableSet<Range<C>> asDescendingSetOfRanges() {
        if (ranges.isEmpty()) {
          return ImmutableSet.of();
        }
        return new RegularImmutableSortedSet<>(ranges.reverse(), Range.<C>rangeLexOrdering().reverse());
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 27K bytes
    - Viewed (0)
  3. guava/src/com/google/common/reflect/Types.java

        }
    
        public Type[] getBounds() {
          return toArray(bounds);
        }
    
        public D getGenericDeclaration() {
          return genericDeclaration;
        }
    
        public String getName() {
          return name;
        }
    
        public String getTypeName() {
          return name;
        }
    
        @Override
        public String toString() {
          return name;
        }
    
        @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 23K bytes
    - Viewed (0)
  4. guava-testlib/src/com/google/common/collect/testing/google/SetGenerators.java

          return ImmutableSet.copyOf(elements);
        }
      }
    
      public static class ImmutableSetUnsizedBuilderGenerator extends TestStringSetGenerator {
        @Override
        protected Set<String> create(String[] elements) {
          ImmutableSet.Builder<String> builder = ImmutableSet.builder();
          for (String e : elements) {
            builder.add(e);
          }
          return builder.build();
        }
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/core/convert/LongConversionUtil.java

            if (o == null) {
                return null;
            } else if (o instanceof Long) {
                return (Long) o;
            } else if (o instanceof Number) {
                return ((Number) o).longValue();
            } else if (o instanceof String) {
                return toLong((String) o);
            } else if (o instanceof java.util.Date) {
                if (pattern != null) {
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/es/log/allcommon/EsAbstractEntity.java

                this.id = id;
                myuniqueByProperty("_id");
                return this;
            }
    
            public String id() {
                return id;
            }
    
            public DocMeta version(Long version) {
                this.version = version;
                return this;
            }
    
            public Long version() {
                return version;
            }
    
            public DocMeta seqNo(Long seqNo) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  7. cmd/batch-handlers.go

    		*b = tmpSlice
    		return nil
    	}
    	// try string
    	tmpStr := ""
    	if err := value.Decode(&tmpStr); err == nil {
    		*b = []string{tmpStr}
    		return nil
    	}
    	return fmt.Errorf("unable to decode %s", value.Value)
    }
    
    // F - return prefix(es) as slice
    func (b *BatchJobPrefix) F() []string {
    	return *b
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/es/config/bsbhv/BsCrawlingInfoBhv.java

        @Override
        public String asTableDbName() {
            return asEsIndexType();
        }
    
        @Override
        protected String asEsIndex() {
            return "fess_config.crawling_info";
        }
    
        @Override
        public String asEsIndexType() {
            return "crawling_info";
        }
    
        @Override
        public String asEsSearchType() {
            return "crawling_info";
        }
    
        @Override
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/es/config/bsbhv/BsElevateWordToLabelBhv.java

        @Override
        public String asTableDbName() {
            return asEsIndexType();
        }
    
        @Override
        protected String asEsIndex() {
            return "fess_config.elevate_word_to_label";
        }
    
        @Override
        public String asEsIndexType() {
            return "elevate_word_to_label";
        }
    
        @Override
        public String asEsSearchType() {
            return "elevate_word_to_label";
        }
    
        @Override
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/es/config/bsbhv/BsJobLogBhv.java

        @Override
        public String asTableDbName() {
            return asEsIndexType();
        }
    
        @Override
        protected String asEsIndex() {
            return "fess_config.job_log";
        }
    
        @Override
        public String asEsIndexType() {
            return "job_log";
        }
    
        @Override
        public String asEsSearchType() {
            return "job_log";
        }
    
        @Override
        public JobLogDbm asDBMeta() {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 9.5K bytes
    - Viewed (0)
Back to top